<?php

declare(strict_types=1);

namespace App\Job;

use Hyperf\AsyncQueue\Job;

class ActivityJob extends Job
{
    public $params;

    /**
     * 任务执行失败后的重试次数，即最大执行次数为 $maxAttempts+1 次
     */
    protected  int $maxAttempts = 3;


    public function __construct($params)
    {
        // 这里最好是普通数据，不要使用携带 IO 的对象，比如 PDO 对象
        $this->params = $params;
    }

    public function handle()
    {
        #执行业务逻辑
        $this->finishActivityById($this->params['activity_id']);
        return true;
    }

    /**
     * job处理结束活动方法
     * @param $id
     * @return bool
     */
    protected function finishActivityById($id){
        #执行业务逻辑

        return true;
    }
}
